package com.cjlgb.design.upms.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author WFT
 * @date 2019/8/29
 * description: 系统角色,输入输出通道
 */
public interface SysRoleChannel {

    /**
     * 消息通道
     * @return org.springframework.messaging.MessageChannel
     */
    @Output(value = "sys_role_topic_output")
    MessageChannel output();

    String INPUT = "sys_role_topic_input";

    /**
     * 订阅通道
     * @return org.springframework.messaging.SubscribableChannel
     */
    @Input(value = INPUT)
    SubscribableChannel input();

}
